package site.teamo.biu.flink.sdk.function;

import org.apache.flink.streaming.api.functions.KeyedProcessFunction;
import org.apache.flink.streaming.api.functions.ProcessFunction;
import site.teamo.biu.flink.sdk.job.JobContext;

/**
 * @author haocongshun
 * @date 2023/07/25 15:38:17
 */
public abstract class AbstractKeyedProcessFunction<KEY, IN, OUT> extends KeyedProcessFunction<KEY, IN, OUT> {

    protected String name;

    protected JobContext context;

    public AbstractKeyedProcessFunction(String name, JobContext context) {
        this.name = name;
        this.context = context;
    }
}
